package test.taskengine;

import java.util.Map;

import org.apache.log4j.Logger;

import com.liusy.taskengine.taskmodel.AbstractDBTaskModel;


/**
 * 批量执行sql的具体任务
 * 
 * @author liusy 2012-12-11
 */
public class SqlTaskModel extends AbstractDBTaskModel{
	
	private static Logger log = Logger.getLogger(SqlTaskModel.class);

	public SqlTaskModel(Map<String, Object> rowMap) {
		super(rowMap);
	}

	@Override
	public String getSql() {
		return "select wm_concat(t.consumer_id) customerId  from ex_customer_sub t where t.consumer_name = '"+rowMap.get("name")+"' group by t.consumer_name";
	}
	
}
